package com.wyp168.socket.utils;

import java.io.ByteArrayOutputStream;
import java.io.InputStream;

public class StreamUtils {

    /**
     * 将流转换成数组返回
     * @param is 输入流
     * @return  返回一个字节数组
     * @throws Exception    抛出异常
     */
    public static byte[] streamToByteArray(InputStream is) throws Exception {
        ByteArrayOutputStream bos = new ByteArrayOutputStream();    //创建输出流对象
        byte[] b = new byte[1024];
        int len;
        while ((len = is.read(b)) != -1) {  //循环读取
            bos.write(b, 0, len);   //把读取到的数据，写入bos中
        }
        byte[] array = bos.toByteArray();   //将bos 转换成字节数组
        //关闭资源
        bos.close();
        return array;
    }

//    public String streamToString(InputStream is) throws Exception {
//
//    }
}
